/**
 * Created by yt758 on 2025/2/22.
 * */
#ifndef RSPTASK_PYSHM
#define RSPTASK_PYSHM

#include "TaskModule.h"
#include "../GlobalParameters.h"

extern "C" BaseObject *createRspTask();
extern "C" void destroyRspTask(BaseObject *p);

class RspTask : public TaskModule {
public:
RspTask();

~RspTask();

void onCompute(buffer_table_t *input, buffer_table_t *output) override;

private:
    int shm_fd;        // 共享内存文件描述符
    std::complex<float>* shared_memory; // 共享内存指针，存储复数数据
};

#endif //TASK2_PYSHM
